package com.xqc.rabbit.simple;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.xqc.rabbit.ConnectionUtils;

/**
* @author 作者 Gavin.Dai/SNSSZ00036
* @dateTime 创建时间：2020年8月11日 下午1:09:15
* @version V1.0.0
* 类说明
*/
public class SimpleProduct {
	public static final String SIMPLE_QUEUE = "park_queue";

	public static void main(String[] args) throws IOException, TimeoutException {
		Connection conn = ConnectionUtils.getConn();
		//声明信道
		Channel channel = conn.createChannel();
		//声明队列,durable true声明一个持久队列（该队列将在服务器重新启动后继续存在）,exclusive=true声明独占队列（仅限于此连接）
		//autoDelete true服务器将在不再使用时删除它, arguments队列的其他属性
		channel.queueDeclare(SIMPLE_QUEUE, true, false, false, null);
		//消息内容
		String message = "简单对列模式";
		//发布消息
		channel.basicPublish("", SIMPLE_QUEUE, null, message.getBytes());
		//关闭
		channel.close();
		conn.close();
	}
}
